package com.ky.pro.big.data.spark.sql.cusotmer.optimizer

import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.catalyst.plans.logical.LogicalPlan
import org.apache.spark.sql.catalyst.rules.Rule


case class KyOptimizerRule(session: SparkSession) extends Rule[LogicalPlan] {
  override def apply(plan: LogicalPlan): LogicalPlan = {
    logWarning("executing ky optimizer rule")
    plan
  }
}
